/**
 * 数据层：封装数据库操作(数据的增删改查)
 * 安装第三方模块：mysql或mysql2(MySQL8.0以上版本)
 */
const mysql = require("mysql2");
const config = require("../config");
//创建连接池对象
const pool = mysql.createPool(config.dbconfig);

module.exports = {
    /**
     * 执行数据的增删改查
     * @param  sql sql语句
     * @param  params 参数数组
     * @param  callback 回调函数
     */
    query: (sql, params, callback) => {
        console.log(sql);
        pool.getConnection((err1, conn) => {
            if (err1) {
                callback(err1.message, null);
            } else {
                conn.query(sql, params, (err2, results) => {
            
                    if (err2) {
                        callback(err2.message, null);
                    } else {
                        callback(null, results);
                    }
                //释放连接
                conn.release();
                })
            }
        })
    }
}